#ifndef __MyTask_H__
#define __MyTask_H__

#include "TcpConnection.h"

class MyTask
{
public:
    MyTask(const string & msg,const TcpConnectionPtr & con)
    : _msg(msg)
    , _con(con)
    {}

    void process()
    {
        //如何处理数据
        _msg;

        //子线程调用process函数
        //此处如果直接将处理完的数据进行send
        //那么就是由子线程发送给客户端了
        /* _con->send(_msg); */

        //应该由子线程将处理完的数据发送给主线程
        //再由主线程发送给客户端
        _con->sendInLoop(_msg);
    }
private:
    string _msg;
    TcpConnectionPtr _con;
};





#endif

